package com.test.myrxjava.core;

public interface Observer<T> {//观察者接口

    void onSubscribe();

    void onNext(T t);

    void onComplete();

    void onError(Throwable throwable);

}
